package com.hhf.rrd.readtime_report;

import org.apache.flink.table.functions.ScalarFunction;

import java.sql.Timestamp;

/**
 * udf
 *
 * @author huanghaifeng15
 * @date 2022/2/12 07:54
 **/
public class MyFloor extends ScalarFunction {

    public Timestamp eval(Timestamp timestamp) {
        return new Timestamp(timestamp.getTime() + 1000);
    }
}
